package com.antstorm.statistics.service.mqtt;

import org.eclipse.paho.client.mqttv3.MqttMessage;

/**
 * mqtt消息处理器
 */
public interface MqttMsgHandler {

    void initTopic();


    void handle(MqttMessage mqttMessage);
}
